package com.lzq.mq.broker.rebalance.strategy;

import com.lzq.mq.broker.rebalance.ConsumerInstance;
import lombok.Getter;
import lombok.Setter;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;

/**
 * 存储需要参与重平衡的信息
 */
@Setter
@Getter
public class ReBalanceInfo {

    /**
     * 存储topic下的消费者实例
     */
    private Map<String, List<ConsumerInstance>> consumeInstanceMap;

    /**
     * 存储topic下发生过变化的消费者组
     * key: topic
     * value: 消费组名称
     */
    private Map<String, Set<String>> changeConsumerGroupMap = new HashMap<>();

}
